package com.zxh.mall.order.utils;

import com.zxh.mall.common.constant.OrderConstant;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

/**
 * @author zhengxh
 * @version 1.0
 * @date 2024/5/23 - 05 - 23 - 14:50
 * @description com.zxh.mall.order.utils
 */
@Component
@RocketMQMessageListener(topic = OrderConstant.ROCKETMQ_ORDER_TOPIC,consumerGroup = "${rocketmq.consumer.group}")
public class OrderMsgConsumer implements RocketMQListener<String> {
    @Override
    public void onMessage(String s) {
        // TODO 订单关单的逻辑实现
        System.out.println("收到的消息："+ s);
    }
}
